#include "pair.h"
#include <iostream>

PairEndpoint::PairEndpoint(const std::string& address, bool isBind) {
    context = zmq::context_t();  // 使用默认构造函数初始化 context
    socket = zmq::socket_t(context, zmq::socket_type::pair);  // 使用 context 初始化 socket
    if (isBind){
        socket.bind(address);  // 绑定到指定地址
    } else {
        socket.connect(address);  // 连接到指定地址
    }
}

void PairEndpoint::receiveMessage(zmq::recv_flags recvFlag) {
    zmq::message_t message;
    socket.recv(message, recvFlag);  // 使用传入的标志
    std::cout << "Received: " << message.to_string() << std::endl;
}


void PairEndpoint::sendMessage(const std::string& message) {
    socket.send(zmq::buffer(message), zmq::send_flags::none);  // 发送消息
    std::cout << "Sent: " << message << std::endl;
}
